var mysql  = require('mysql');  //调用MySQL模块
var db={};
var dbsetting={
    host     : 'localhost',       //主机
    user     : 'root',               //MySQL认证用户名
    password : 'root',        //MySQL认证用户密码
    port: '3306',                   //端口号
    database : 'nodedb'
};
db.query=function(sql,fn) {
    //创建一个connection
    var connection = mysql.createConnection(dbsetting);
    //创建一个connection
    connection.connect(function(err){
        if(err){
            console.log('[query] - :'+err);
            return;
        }
        console.log('连接成功');
    });
    if(!sql){
        return;
    }
    //执行SQL语句
    connection.query(sql, function(err, rows, fields) {
        if (err) {
            console.log('[query] - :'+err);
            return;
        }
        console.log('The solution is: ', rows[0]);
        fn(rows);
    });
    //关闭connection
    connection.end(function(err){
        if(err){
            return;
        }
        console.log('连接关闭');
    });
}
module.exports=db;
